8d79aaad136d61fa7c04d36cfcbb1944bd141f83,components/camel-hbase/src/test/java/org/apache/camel/component/hbase/HBaseProducerTest.java,HBaseProducerTest,testPutAndGetMultiColumns,#,214
Before Change
Endpoint endpoint = context.getEndpoint("direct:start");
Exchange exchange = endpoint.createExchange(ExchangePattern.InOut);
exchange.getIn().setHeader(HbaseAttribute.HBASE_ROW_ID.asHeader(), key[0]);
exchange.getIn().setHeader(HbaseAttribute.HBASE_FAMILY.asHeader(), family[0]);
exchange.getIn().setHeader(HbaseAttribute.HBASE_QUALIFIER.asHeader(), column[0]);
exchange.getIn().setHeader(HbaseAttribute.HBASE_ROW_ID.asHeader(2), key[0]);
exchange.getIn().setHeader(HbaseAttribute.HBASE_FAMILY.asHeader(2), family[1]);
exchange.getIn().setHeader(HbaseAttribute.HBASE_QUALIFIER.asHeader(2), column[1]);
exchange.getIn().setHeader(HBaseConstants.OPERATION, HBaseConstants.GET);
After Change
ProducerTemplate template = context.createProducerTemplate();
Endpoint endpoint = context.getEndpoint("direct:start");
Exchange exchange = endpoint.createExchange(ExchangePattern.InOut);
for (int col = 0; col < column[0].length; col++) {
exchange.getIn().setHeader(HbaseAttribute.HBASE_ROW_ID.asHeader(col + 1), key[0]);
exchange.getIn().setHeader(HbaseAttribute.HBASE_FAMILY.asHeader(col + 1), family[0]);
exchange.getIn().setHeader(HbaseAttribute.HBASE_QUALIFIER.asHeader(col + 1), column[0][col]);
}